479f89fc3489ef6ccb1dfd23cf0a49654d3af47a,src/test/java/io/reactivex/internal/operators/observable/ObservableTakeLastOneTest.java,ObservableTakeLastOneTest,testUnsubscribesFromUpstream,#,62

Before Change


                unsubscribed.set(true);
            }
        };
        Observable.just(1).doOnDispose(unsubscribeAction)
                .takeLast(1).subscribe();
        assertTrue(unsubscribed.get());
    }

After Change


                unsubscribed.set(true);
            }
        };
        Observable.just(1)
        .concatWith(Observable.<Integer>never())
        .doOnDispose(unsubscribeAction)
        .takeLast(1)
        .subscribe()